var mysql = require('mysql');
// 连接数据库
var connection = mysql.createConnection({
 port:"3306",
 user: 'root',
 password: '123456',
 database: 'akb48'
});
// 判断数据库是否连接成功
connection.connect(function(err){
 if(err){
 console.log('[query] - :'+err);
 return;
 }
 console.log('[connection connect] MySQL数据库连接成功!');
});
// 使用SQL查询语句
connection.query('USE akb48');
connection.query('SELECT * FROM akb7', function(error, result, fields) {
 if(error) {
 console.log('查询语句有误！');
 } else {
 console.log(result);
 }
});
//关闭连接
connection.end(function (err) {
 if (err) {
 return;
 }
  console.log('[connection end] 关闭数据库连接!');
});